package com.atguigu.sparkcore.rdd.file.text

import com.atguigu.sparkcore.util.MySparkContextUtil

/**
 * 读取TextFile
 * author 剧情再美终是戏
 * mail 13286520398@163.com
 * date 2020/1/8 19:20
 * version 1.0
 **/
object RTextFile {

  def main(args: Array[String]): Unit = {

    // 获取sparkContext
    val sc = MySparkContextUtil.get(args)

    // 读取文件
    val userRdd = sc.textFile("c:/user.txt")

    // 解析文件
    val result = userRdd.map { line =>
      val splits = line.split("\t")
      (splits(0), splits(1))
    }

    // 输出解析后的结果
    result.foreach(println)

    // 关闭资源
    MySparkContextUtil.close(sc)
  }

}
